//package com.xiaozhen.mqtt.listener;
//
//import lombok.extern.slf4j.Slf4j;
//import net.dreamlu.iot.mqtt.codec.ByteBufferUtil;
//import net.dreamlu.iot.mqtt.codec.MqttQoS;
//import net.dreamlu.iot.mqtt.core.server.event.IMqttMessageListener;
//import org.springframework.stereotype.Service;
//
//import java.nio.ByteBuffer;
//
///**
// * 消息监听
// *
// * @author zhenweisheng
// * @date 2021/10/11 13:46
// * @description:
// */
//@Service
//@Slf4j
//public class MyMqttMessageListener implements IMqttMessageListener {
//
//    @Override
//    public void onMessage(String clientId, String topic, MqttQoS mqttQoS, ByteBuffer byteBuffer) {
//        log.info("clientId:{} topic:{} mqttQoS:{} message:{}", clientId, topic, mqttQoS, ByteBufferUtil.toString(byteBuffer));
//    }
//}
